package com.namo.cchfile.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

import java.util.List;

/**
 * @author WangXin
 * @date 2021/5/12 20:54
 */
@Configuration
public class TestConfig {
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
//    @Bean
//    public void tt() throws MQClientException {
//        // 实例化消费者
//        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("vbss");
//
//        // 设置NameServer的地址
//        consumer.setNamesrvAddr("192.168.99.99:9876");
//
//        // 订阅一个或者多个Topic，以及Tag来过滤需要消费的消息
//        consumer.subscribe("mmmyyy", "*");
//        // 注册回调实现类来处理从broker拉取回来的消息
//        consumer.registerMessageListener(
//                new MessageListenerConcurrently() {
//                    @Override
//                    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
//                        System.out.println( msgs);
//                        System.out.println(context);
//                        // 标记该消息已经被成功消费
//                        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
//                    }
//                });
//        // 启动消费者实例
//        consumer.start();
//    }
}
